package com.xmhmyh.generalframework.framework.redisQueue.consumers;

import com.xmhmyh.generalframework.framework.redisQueue.RedisQueueMessage;

/**
 * redis队列消费者接口
 */
public interface RedisQueueConsumer {
    /**
     * 获取队列名称
     *
     * @return
     */
    String getQueueName();

    /**
     * 获取监听器返回的消息
     *
     * @param redisQueueMessage
     */
    void getMessage(RedisQueueMessage redisQueueMessage) throws InterruptedException;

    /**
     * 获取监听器返回的错误消息
     *
     * @param error
     */
    void error(String error);

}
